// 创建 WebSocket 连接
const socket = new WebSocket("wss://stream.binance.com:9443/stream?streams=btcusdt@ticker/ethusdt@ticker/bnbusdt@ticker/filusdt@ticker/ltcusdt@ticker/uniusdt@ticker/mkrcusdt@ticker/arbusdt@ticker");

// 添加事件处理程序来处理不同的 WebSocket 事件
socket.onopen = (event) => {
   console.log("WebSocket 连接已打开");

   // 在连接打开后发送消息到服务器
   const message =
   {
      "method": "SUBSCRIBE",
      "params":
         [
            "btcusdt@ticker",
            "ethusdt@ticker",
            "bnbusdt@ticker",
            "filusdt@ticker",
            "ltcusdt@ticker",
            "uniusdt@ticker",
            "mkrcusdt@ticker",
            "arbusdt@ticker",
         ],
      "id": 1
   }
      ;
   socket.send(JSON.stringify(message));
};




socket.onmessage = (event) => {

   // // 获取当前时间
   // const currentTime = new Date();

   // // 获取时、分、秒和毫秒
   // const hours = currentTime.getHours();
   // const minutes = currentTime.getMinutes();
   // const seconds = currentTime.getSeconds();
   // const milliseconds = currentTime.getMilliseconds();

   // // 格式化时、分、秒和毫秒，确保它们始终有两位数
   // const formattedHours = hours.toString().padStart(2, '0');
   // const formattedMinutes = minutes.toString().padStart(2, '0');
   // const formattedSeconds = seconds.toString().padStart(2, '0');
   // const formattedMilliseconds = milliseconds.toString().padStart(10, '0');
   // console.log("当前开始时间：", `${formattedHours}:${formattedMinutes}:${formattedSeconds}.${formattedMilliseconds}`);
   const data = JSON.parse(event.data);
   console.log("收到消息：", data);
   // console.log("当前结束时间：", `${formattedHours}:${formattedMinutes}:${formattedSeconds}.${formattedMilliseconds}`);
   // 在这里处理收到的消息

};


socket.onclose = (event) => {
   if (event.wasClean) {
      console.log(`WebSocket 连接已关闭，状态码：${event.code}，原因：${event.reason}`);
   } else {
      console.error("WebSocket 连接断开");
   }
};



socket.onerror = (error) => {
   console.error("WebSocket 错误：", error);
};
